package org.dromara.demo.controller;

import com.baomidou.lock.LockInfo;
import com.baomidou.lock.LockTemplate;
import com.baomidou.lock.annotation.Lock4j;
import com.baomidou.lock.executor.RedissonLockExecutor;
import lombok.extern.slf4j.Slf4j;
import org.dromara.common.core.domain.R;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.time.LocalTime;



/**
 * @Author 刘武贵
 * @Date 2024/8/15 22:00
 * @Description 功能描述：测试分布式锁的样例
 */
@Slf4j
@RestController
@RequestMapping("/demo/redisLock")
public class RedisLockController {

    /**
     * 锁模板
     */
    @Autowired
    private LockTemplate lockTemplate;

    /**
     * 测试lock4j 注解
     * 使用Lock4j注解来实现分布式锁，确保在同一时间内只有一个请求可以执行该方法
     * 此方法演示了在处理过程中如何使用锁来防止并发修改问题
     *
     * @param key 用于锁定的键，用于唯一标识锁
     * @param value 与键关联的值，用于演示
     * @return 操作结果，包括状态和消息
     */
    @Lock4j(keys = {"#key"})
    @GetMapping("/testLock4j")
    public R<String> testLock4j(String key, String value) {
        System.out.println("start:" + key + ",time:" + LocalTime.now().toString());
        try {
            // 模拟一个耗时的操作，例如数据库操作或复杂的业务逻辑
            Thread.sleep(10000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("end :" + key + ",time:" + LocalTime.now().toString());
        return R.ok("操作成功", value);
    }

    /**
     * 测试lock4j 工具
     * 使用Lock4j锁模板测试锁机制
     * 该方法的目的是演示如何在多线程环境中使用锁来安全地访问共享资源
     * 通过传入的key和value模拟对共享资源的操作，以展示锁如何防止数据不一致和竞态条件
     *
     * @param key   共享资源的唯一标识符，用于指定哪个资源将被操作
     * @param value 拟对共享资源进行的操作数据，模拟一次数据更新或访问
     * @return 返回一个封装了字符串的结果对象，其中包含操作结果或错误信息
     */
    @GetMapping("/testLock4jLockTemplate")
    public R<String> testLock4jLockTemplate(String key, String value) {
        // 尝试获取分布式锁，指定锁的键，获取锁的超时时间，锁的持有时间，以及锁的执行器类型
        final LockInfo lockInfo = lockTemplate.lock(key, 30000L, 5000L, RedissonLockExecutor.class);
        // 如果获取锁失败，抛出异常提示业务正在处理中
        if (null == lockInfo) {
            throw new RuntimeException("业务处理中,请稍后再试");
        }
        // 获取锁成功，处理业务
        try {
            // 模拟业务处理过程中的延迟
            try {
                Thread.sleep(8000);
            } catch (InterruptedException e) {
                // 对中断异常进行捕获处理，此处的处理逻辑根据实际需要进行
            }
            System.out.println("执行简单方法1 , 当前线程:" + Thread.currentThread().getName());
        } finally {
            //释放锁
            lockTemplate.releaseLock(lockInfo);
        }
        //结束
        return R.ok("操作成功", value);
    }

}
